Java知识体系

Appearance

技术栈-SpringData JPA-基础使用

看了如看，这篇文档，没有讲什么重点，而是内容格式比较不好，建议投入时间后面改善一下。

一、Spring Data JPA核心价值 ​

1.1 JPA规范解读 ​

JPA（Java Persistence API）作为Java EE的ORM标准规范，定义了以下核心特性：

  • 对象-关系映射元数据（通过注解或XML）
  • 实体管理API（EntityManager）
  • JPQL查询语言
  • 事务控制机制

1.2 Spring Data JPA优势 ​

java
// 传统JPA操作 vs Spring Data JPA
// 传统方式需要手动编写DAO实现
public class UserDaoImpl implements UserDao {
    @PersistenceContext
    private EntityManager em;

    public User findById(Long id) {
        return em.find(User.class, id);
    }
}

// Spring Data JPA只需定义接口
public interface UserRepository extends JpaRepository<User, Long> {
    // 自动实现方法
}

优势对比：

  1. 减少70%以上的样板代码
  2. 内置分页/排序支持
  3. 方法名自动推导查询
  4. 与Spring生态无缝集成

二、核心功能深度解析 ​

2.1 实体映射最佳实践 ​

java
@Entity
@Table(name = "t_user", indexes = {
    @Index(columnList = "email", unique = true)
})
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(length = 64, nullable = false)
    private String name;

    @Enumerated(EnumType.STRING)
    private UserStatus status;

    @OneToMany(mappedBy = "user", cascade = CascadeType.ALL)
    private List<Order> orders = new ArrayList<>();
    
    // 审计字段
    @CreatedDate
    private LocalDateTime createTime;
}

关键注解说明：

  • @DynamicUpdate 实现部分字段更新
  • @Version 实现乐观锁控制
  • @Embedded 组合值对象

2.2 Repository体系解析 ​

接口层级：

  1. CrudRepository 基础CRUD
  2. PagingAndSortingRepository 分页排序
  3. JpaRepository JPA特化接口

自定义Repository示例：

java
public interface CustomUserRepository {
    void customBatchInsert(List<User> users);
}

public class CustomUserRepositoryImpl implements CustomUserRepository {
    @PersistenceContext
    private EntityManager em;

    @Transactional
    public void customBatchInsert(List<User> users) {
        users.forEach(user -> em.persist(user));
    }
}

三、典型场景实战 ​

3.1 动态查询方案 ​

方案对比表：

方式适用场景维护成本
方法名推导简单条件查询低
@Query注解固定复杂查询中
JPA Criteria API动态条件查询高
QueryDSL复杂动态查询中

QueryDSL示例：

java
public List<User> findActiveUsers(String namePrefix) {
    QUser user = QUser.user;
    return queryFactory.selectFrom(user)
        .where(user.name.startsWith(namePrefix)
            .and(user.status.eq(UserStatus.ACTIVE)))
        .fetch();
}

3.2 事务管理要点 ​

java
@Service
@Transactional(readOnly = true)
public class UserService {
    
    @Transactional // 覆盖类级别配置
    public User createUser(User user) {
        // 写操作
    }

    public Page<User> listUsers(Pageable pageable) {
        // 只读查询
    }
}

事务传播机制：

  • REQUIRED（默认）：加入当前事务，没有则新建
  • REQUIRES_NEW：始终新建事务
  • READ_ONLY：优化只读操作

四、性能优化策略 ​

4.1 N+1查询解决方案 ​

问题场景：

java
@Entity
public class Order {
    @ManyToOne(fetch = FetchType.LAZY) // 默认应为LAZY
    private User user;
}

// 错误用法导致N+1查询
List<Order> orders = orderRepository.findAll();
orders.forEach(o -> o.getUser().getName()); // 触发延迟加载

解决方案：

java
public interface OrderRepository extends JpaRepository<Order, Long> {
    @EntityGraph(attributePaths = "user")
    @Query("select o from Order o")
    List<Order> findAllWithUser();
}

4.2 批量操作优化 ​

批量插入优化：

properties
# application.properties
spring.jpa.properties.hibernate.jdbc.batch_size=50
spring.jpa.properties.hibernate.order_inserts=true
java
@Transactional
public void batchInsert(List<User> users) {
    users.forEach(user -> {
        entityManager.persist(user);
        if (i % 50 == 0) { // 配合batch_size
            entityManager.flush();
            entityManager.clear();
        }
    });
}

五、常见问题排查 ​

5.1 典型异常处理 ​

LazyInitializationException：

  • 成因：在事务外访问延迟加载属性
  • 解决方案：
    1. 使用@Transactional保持事务
    2. @EntityGraph预加载关联
    3. DTO投影代替实体返回

QueryTimeoutException：

  • 排查方向：
    1. 检查SQL执行计划
    2. 添加必要索引
    3. 优化JPQL/HQL
    4. 设置合理的超时时间：
    java
    @QueryHints(@QueryHint(name = "javax.persistence.query.timeout", value = "1000"))

六、进阶开发技巧 ​

6.1 审计功能实现 ​

java
@Configuration
@EnableJpaAuditing
public class JpaConfig {
    @Bean
    public AuditorAware<String> auditorProvider() {
        return () -> Optional.ofNullable(SecurityContextHolder.getContext())
            .map(SecurityContext::getAuthentication)
            .map(Authentication::getName);
    }
}

@Entity
@EntityListeners(AuditingEntityListener.class)
public class User {
    @CreatedBy
    private String createdBy;
    
    @LastModifiedDate
    private LocalDateTime modifiedAt;
}

6.2 多数据源配置 ​

java
@Configuration
@EnableJpaRepositories(
    basePackages = "com.example.primary",
    entityManagerFactoryRef = "primaryEmf",
    transactionManagerRef = "primaryTm"
)
public class PrimaryConfig {
    
    @Bean
    @Primary
    public LocalContainerEntityManagerFactoryBean primaryEmf(
            DataSource dataSource, 
            JpaVendorAdapter adapter) {
        LocalContainerEntityManagerFactoryBean emf = new LocalContainerEntityManagerFactoryBean();
        emf.setDataSource(dataSource);
        emf.setPackagesToScan("com.example.primary");
        emf.setJpaVendorAdapter(adapter);
        return emf;
    }
}

最佳实践建议：

  1. 生产环境必须启用SQL日志：
properties
spring.jpa.show-sql=true
logging.level.org.hibernate.SQL=DEBUG
logging.level.org.hibernate.type.descriptor.sql.BasicBinder=TRACE
  1. 版本控制策略：
  • 使用Flyway/Liquibase管理DDL变更
  • 实体变更与数据库版本严格同步
  1. 性能监控：
java
@Bean
public MetricsJpaQueryExecutionListener metricsJpaListener() {
    return new MetricsJpaQueryExecutionListener();
}

本指南涵盖了Spring Data JPA的核心开发场景，实际项目中应根据具体需求选择合适的实现方案。建议通过Spring Boot的Data JPA Starter快速开始，并持续关注官方文档的更新动态。